6b35d65b44a3a60d99492c8786854e7dd4634b1e,src/test/java/org/graylog/plugins/beats/BeatsCodecTest.java,BeatsCodecTest,decodeMessagesHandleGenericBeatMessages,#,122
Before Change
public void decodeMessagesHandleGenericBeatMessages() throws Exception {
final byte[] json = Resources.toByteArray(Resources.getResource("BeatsCodecTest/generic.json"));
final RawMessage rawMessage = new RawMessage(json);
final Collection<Message> messages = codec.decodeMessages(rawMessage);
assertThat(messages)
.isNotNull()
.hasSize(1);
final Message message = messages.iterator().next();
assertThat(message.getSource()).isEqualTo("unknown");
assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));
assertThat(message.getField("facility")).isEqualTo("genericbeat");
After Change
public void decodeMessagesHandleGenericBeatMessages() throws Exception {
final byte[] json = Resources.toByteArray(Resources.getResource("generic.json"));
final RawMessage rawMessage = new RawMessage(json);
final Message message = codec.decode(rawMessage);
assertThat(message).isNotNull();
assertThat(message.getSource()).isEqualTo("unknown");
assertThat(message.getTimestamp()).isEqualTo(new DateTime(2016, 4, 1, 0, 0, DateTimeZone.UTC));